//*********************************************************************
//系统名称：IT健康管理
//Copyright(C)2017-2021 NARI Information and Communication Technology
//Branch. All rights reserved.
//版本信息：ithmp-V1.000-001
//版本                     日期              作者       变更记录
//ithmp-V1.000-001      2021/05/25          徐涛　      新建
//*********************************************************************
package com.example.kafka.enums;

import java.util.stream.Stream;

/**
 * kafka topic 枚举类
 * 通过kafka传输消息，总线式的程序设计，类似于计算机主板总线
 *
 * @author xutao
 */
public enum KafkaTopicEnum {

    // 指标数据推送
    INDEX_DATA_REPORT("index_date_south_grid", "index_date_south_grid_key");

    private final String topic;

    private final String key;

    KafkaTopicEnum(String topic, String key) {
        this.topic = topic;
        this.key = key;
    }

    public String getTopic() {
        return topic;
    }

    public String getKey() {
        return key;
    }

    public static KafkaTopicEnum codeOf(String key) {
        return Stream.of(values()).filter(category -> category.getKey() == key).findFirst().orElse(INDEX_DATA_REPORT);
    }

}
